package com.cloud.async.error.impl;

import com.cloud.async.error.ErrorHandler;
import com.cloud.async.flow.util.timer.SystemClock;
import com.cloud.async.result.core.body.ResultBody;

public class DefaultErrorHandler implements ErrorHandler {

    @Override
    public <T> ResultBody<T> handleError(String taskId, Class<T> responseType, Exception e) {
        return new ResultBody<>(
                responseType,
                -1L,
                SystemClock.now(),
                e.getMessage()
        );
    }

}
